package com.codeduck.redis.sub;

import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;

/**
 * 实现MessageListener接口，对某个TOPIC进行监听
 *
 * @author: <a href="mailto:codeduck@163.com">Codeduck</a>
 * @createDate: 2022-01-07
 */
@Slf4j
public class TestChannelTopicMessageListener implements MessageListener {

    @Override
    public void onMessage(Message message, byte[] pattern) {
        log.info("######## 收到 ChannelTopic 消息 ########");
        log.info("线程编号: [{}]" , Thread.currentThread().getName());
        log.info("message: [{}]" , message); // 可获得到具体的消息内容，不过是二进制数组，需要我们自己序列化。
        log.info("pattern: [{}]" , new String(pattern)); // 发布的 Topic 的内容。
    }
}
